31f33cbda2651524e0bae1ab405b29264acd1e68,src/main/java/com/tesco/mewbase/client/impl/ClientImpl.java,ClientImpl,writeQuery,#BsonObject#Consumer#CompletableFuture#,123
Before Change
private void writeQuery(BsonObject frame, Consumer<QueryResult> resultHandler, CompletableFuture cf) {
int queryID = nextQueryId.getAndIncrement();
frame.put(Protocol.QUERY_QUERYID, queryID);
Buffer buffer = Protocol.encodeFrame(Protocol.QUERY_FRAME, frame);
queryResultHandlers.put(queryID, resultHandler);
write(cf, buffer, null);
}
After Change
int queryID = requestIDSequence.getAndIncrement();
frame.put(Protocol.QUERY_QUERYID, queryID);
queryResultHandlers.put(queryID, resultHandler);
write(cf, Protocol.QUERY_FRAME, frame);
}